# -*- coding: utf-8 -*-

#  Copyright 2022 Deep Learning on Flink Authors
# 
#  Licensed under the Apache License, Version 2.0 (the "License");
#  you may not use this file except in compliance with the License.
#  You may obtain a copy of the License at
# 
#      http://www.apache.org/licenses/LICENSE-2.0
# 
#  Unless required by applicable law or agreed to in writing, software
#  distributed under the License is distributed on an "AS IS" BASIS,
#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
#  See the License for the specific language governing permissions and
#  limitations under the License.

# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: node.proto

import sys
_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
from google.protobuf.internal import enum_type_wrapper
from google.protobuf import descriptor as _descriptor
from google.protobuf import message as _message
from google.protobuf import reflection as _reflection
from google.protobuf import symbol_database as _symbol_database
# @@protoc_insertion_point(imports)

_sym_db = _symbol_database.Default()




DESCRIPTOR = _descriptor.FileDescriptor(
  name='node.proto',
  package='',
  syntax='proto3',
  serialized_options=_b('\n org.flinkextended.flink.ml.protoB\nNodeProtosP\001'),
  serialized_pb=_b('\n\nnode.proto\"0\n\x11NodeStatusMessage\x12\x1b\n\x06status\x18\x01 \x01(\x0e\x32\x0b.NodeStatus\"\x9f\x01\n\x08NodeSpec\x12\x10\n\x08roleName\x18\x01 \x01(\t\x12\r\n\x05index\x18\x02 \x01(\x05\x12\n\n\x02ip\x18\x03 \x01(\t\x12\x13\n\x0b\x63lient_port\x18\x04 \x01(\x05\x12#\n\x05props\x18\x05 \x03(\x0b\x32\x14.NodeSpec.PropsEntry\x1a,\n\nPropsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"v\n\x08MLJobDef\x12\x0c\n\x04name\x18\x01 \x01(\t\x12#\n\x05tasks\x18\x02 \x03(\x0b\x32\x14.MLJobDef.TasksEntry\x1a\x37\n\nTasksEntry\x12\x0b\n\x03key\x18\x01 \x01(\x05\x12\x18\n\x05value\x18\x02 \x01(\x0b\x32\t.NodeSpec:\x02\x38\x01\"&\n\x0cMLClusterDef\x12\x16\n\x03job\x18\x01 \x03(\x0b\x32\t.MLJobDef\"(\n\x0cNodeSpecList\x12\x18\n\x05nodes\x18\x01 \x03(\x0b\x32\t.NodeSpec\"\"\n\x0fNodeSpecRequest\x12\x0f\n\x07message\x18\x01 \x01(\t\"O\n\x10NodeSpecResponse\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x1c\n\tnode_spec\x18\x02 \x01(\x0b\x32\t.NodeSpec\x12\x0f\n\x07message\x18\x03 \x01(\t\"%\n\x12NodeRestartRequest\x12\x0f\n\x07message\x18\x01 \x01(\t\"4\n\x13NodeRestartResponse\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0f\n\x07message\x18\x02 \x01(\t\"\"\n\x0fNodeStopRequest\x12\x0f\n\x07message\x18\x01 \x01(\t\"1\n\x10NodeStopResponse\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0f\n\x07message\x18\x02 \x01(\t\"*\n\x0c\x43olumnInfoPB\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0c\n\x04type\x18\x02 \x01(\t\"\xf2\x03\n\x0c\x43ontextProto\x12\x0c\n\x04mode\x18\x01 \x01(\t\x12\x10\n\x08roleName\x18\x02 \x01(\t\x12\r\n\x05index\x18\x03 \x01(\x05\x12;\n\x0froleParallelism\x18\x04 \x03(\x0b\x32\".ContextProto.RoleParallelismEntry\x12\x1e\n\x07\x63luster\x18\x05 \x01(\x0b\x32\r.MLClusterDef\x12\'\n\x05props\x18\x06 \x03(\x0b\x32\x18.ContextProto.PropsEntry\x12\x12\n\nuserScript\x18\x07 \x01(\t\x12\x10\n\x08identity\x18\x08 \x01(\t\x12\x10\n\x08\x66uncName\x18\t \x01(\t\x12\x0f\n\x07\x66\x61ilNum\x18\n \x01(\x05\x12\x14\n\x0coutQueueName\x18\x0b \x01(\t\x12\x13\n\x0binQueueName\x18\x0c \x01(\t\x12\x17\n\x0foutQueueMMapLen\x18\r \x01(\x03\x12\x16\n\x0einQueueMMapLen\x18\x0e \x01(\x03\x12\"\n\x0b\x63olumnInfos\x18\x0f \x03(\x0b\x32\r.ColumnInfoPB\x1a\x36\n\x14RoleParallelismEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x05:\x02\x38\x01\x1a,\n\nPropsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"!\n\x0e\x43ontextRequest\x12\x0f\n\x07message\x18\x01 \x01(\t\"P\n\x0f\x43ontextResponse\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x1e\n\x07\x63ontext\x18\x02 \x01(\x0b\x32\r.ContextProto\x12\x0f\n\x07message\x18\x03 \x01(\t\"!\n\x11NodeSimpleRequest\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\"3\n\x12NodeSimpleResponse\x12\x0c\n\x04\x63ode\x18\x01 \x01(\x05\x12\x0f\n\x07message\x18\x02 \x01(\t\"F\n\x14\x46inishWorkerResponse\x12\x0f\n\x07workers\x18\x01 \x03(\x05\x12\x0c\n\x04\x63ode\x18\x02 \x01(\x05\x12\x0f\n\x07message\x18\x03 \x01(\t*^\n\nNodeStatus\x12\x0f\n\x0bNODE_UNKNOW\x10\x00\x12\r\n\tNODE_INIT\x10\x01\x12\r\n\tNODE_FAIL\x10\x02\x12\x10\n\x0cNODE_RUNNING\x10\x03\x12\x0f\n\x0bNODE_FINISH\x10\x04\x42\x30\n org.flinkextended.flink.ml.protoB\nNodeProtosP\x01\x62\x06proto3')
)

_NODESTATUS = _descriptor.EnumDescriptor(
  name='NodeStatus',
  full_name='NodeStatus',
  filename=None,
  file=DESCRIPTOR,
  values=[
    _descriptor.EnumValueDescriptor(
      name='NODE_UNKNOW', index=0, number=0,
      serialized_options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='NODE_INIT', index=1, number=1,
      serialized_options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='NODE_FAIL', index=2, number=2,
      serialized_options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='NODE_RUNNING', index=3, number=3,
      serialized_options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='NODE_FINISH', index=4, number=4,
      serialized_options=None,
      type=None),
  ],
  containing_type=None,
  serialized_options=None,
  serialized_start=1547,
  serialized_end=1641,
)
_sym_db.RegisterEnumDescriptor(_NODESTATUS)

NodeStatus = enum_type_wrapper.EnumTypeWrapper(_NODESTATUS)
NODE_UNKNOW = 0
NODE_INIT = 1
NODE_FAIL = 2
NODE_RUNNING = 3
NODE_FINISH = 4



_NODESTATUSMESSAGE = _descriptor.Descriptor(
  name='NodeStatusMessage',
  full_name='NodeStatusMessage',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='status', full_name='NodeStatusMessage.status', index=0,
      number=1, type=14, cpp_type=8, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=14,
  serialized_end=62,
)


_NODESPEC_PROPSENTRY = _descriptor.Descriptor(
  name='PropsEntry',
  full_name='NodeSpec.PropsEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='NodeSpec.PropsEntry.key', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value', full_name='NodeSpec.PropsEntry.value', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=_b('8\001'),
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=180,
  serialized_end=224,
)

_NODESPEC = _descriptor.Descriptor(
  name='NodeSpec',
  full_name='NodeSpec',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='roleName', full_name='NodeSpec.roleName', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='index', full_name='NodeSpec.index', index=1,
      number=2, type=5, cpp_type=1, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='ip', full_name='NodeSpec.ip', index=2,
      number=3, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='client_port', full_name='NodeSpec.client_port', index=3,
      number=4, type=5, cpp_type=1, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='props', full_name='NodeSpec.props', index=4,
      number=5, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[_NODESPEC_PROPSENTRY, ],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=65,
  serialized_end=224,
)


_MLJOBDEF_TASKSENTRY = _descriptor.Descriptor(
  name='TasksEntry',
  full_name='MLJobDef.TasksEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='MLJobDef.TasksEntry.key', index=0,
      number=1, type=5, cpp_type=1, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value', full_name='MLJobDef.TasksEntry.value', index=1,
      number=2, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=_b('8\001'),
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=289,
  serialized_end=344,
)

_MLJOBDEF = _descriptor.Descriptor(
  name='MLJobDef',
  full_name='MLJobDef',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='name', full_name='MLJobDef.name', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='tasks', full_name='MLJobDef.tasks', index=1,
      number=2, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[_MLJOBDEF_TASKSENTRY, ],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=226,
  serialized_end=344,
)


_MLCLUSTERDEF = _descriptor.Descriptor(
  name='MLClusterDef',
  full_name='MLClusterDef',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='job', full_name='MLClusterDef.job', index=0,
      number=1, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=346,
  serialized_end=384,
)


_NODESPECLIST = _descriptor.Descriptor(
  name='NodeSpecList',
  full_name='NodeSpecList',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='nodes', full_name='NodeSpecList.nodes', index=0,
      number=1, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=386,
  serialized_end=426,
)


_NODESPECREQUEST = _descriptor.Descriptor(
  name='NodeSpecRequest',
  full_name='NodeSpecRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='message', full_name='NodeSpecRequest.message', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=428,
  serialized_end=462,
)


_NODESPECRESPONSE = _descriptor.Descriptor(
  name='NodeSpecResponse',
  full_name='NodeSpecResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='code', full_name='NodeSpecResponse.code', index=0,
      number=1, type=5, cpp_type=1, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='node_spec', full_name='NodeSpecResponse.node_spec', index=1,
      number=2, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='message', full_name='NodeSpecResponse.message', index=2,
      number=3, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=464,
  serialized_end=543,
)


_NODERESTARTREQUEST = _descriptor.Descriptor(
  name='NodeRestartRequest',
  full_name='NodeRestartRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='message', full_name='NodeRestartRequest.message', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=545,
  serialized_end=582,
)


_NODERESTARTRESPONSE = _descriptor.Descriptor(
  name='NodeRestartResponse',
  full_name='NodeRestartResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='code', full_name='NodeRestartResponse.code', index=0,
      number=1, type=5, cpp_type=1, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='message', full_name='NodeRestartResponse.message', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=584,
  serialized_end=636,
)


_NODESTOPREQUEST = _descriptor.Descriptor(
  name='NodeStopRequest',
  full_name='NodeStopRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='message', full_name='NodeStopRequest.message', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=638,
  serialized_end=672,
)


_NODESTOPRESPONSE = _descriptor.Descriptor(
  name='NodeStopResponse',
  full_name='NodeStopResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='code', full_name='NodeStopResponse.code', index=0,
      number=1, type=5, cpp_type=1, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='message', full_name='NodeStopResponse.message', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=674,
  serialized_end=723,
)


_COLUMNINFOPB = _descriptor.Descriptor(
  name='ColumnInfoPB',
  full_name='ColumnInfoPB',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='name', full_name='ColumnInfoPB.name', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='type', full_name='ColumnInfoPB.type', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=725,
  serialized_end=767,
)


_CONTEXTPROTO_ROLEPARALLELISMENTRY = _descriptor.Descriptor(
  name='RoleParallelismEntry',
  full_name='ContextProto.RoleParallelismEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='ContextProto.RoleParallelismEntry.key', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value', full_name='ContextProto.RoleParallelismEntry.value', index=1,
      number=2, type=5, cpp_type=1, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=_b('8\001'),
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=1168,
  serialized_end=1222,
)

_CONTEXTPROTO_PROPSENTRY = _descriptor.Descriptor(
  name='PropsEntry',
  full_name='ContextProto.PropsEntry',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key', full_name='ContextProto.PropsEntry.key', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value', full_name='ContextProto.PropsEntry.value', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=_b('8\001'),
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=180,
  serialized_end=224,
)

_CONTEXTPROTO = _descriptor.Descriptor(
  name='ContextProto',
  full_name='ContextProto',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='mode', full_name='ContextProto.mode', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='roleName', full_name='ContextProto.roleName', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='index', full_name='ContextProto.index', index=2,
      number=3, type=5, cpp_type=1, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='roleParallelism', full_name='ContextProto.roleParallelism', index=3,
      number=4, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='cluster', full_name='ContextProto.cluster', index=4,
      number=5, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='props', full_name='ContextProto.props', index=5,
      number=6, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='userScript', full_name='ContextProto.userScript', index=6,
      number=7, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='identity', full_name='ContextProto.identity', index=7,
      number=8, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='funcName', full_name='ContextProto.funcName', index=8,
      number=9, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='failNum', full_name='ContextProto.failNum', index=9,
      number=10, type=5, cpp_type=1, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='outQueueName', full_name='ContextProto.outQueueName', index=10,
      number=11, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='inQueueName', full_name='ContextProto.inQueueName', index=11,
      number=12, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='outQueueMMapLen', full_name='ContextProto.outQueueMMapLen', index=12,
      number=13, type=3, cpp_type=2, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='inQueueMMapLen', full_name='ContextProto.inQueueMMapLen', index=13,
      number=14, type=3, cpp_type=2, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='columnInfos', full_name='ContextProto.columnInfos', index=14,
      number=15, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[_CONTEXTPROTO_ROLEPARALLELISMENTRY, _CONTEXTPROTO_PROPSENTRY, ],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=770,
  serialized_end=1268,
)


_CONTEXTREQUEST = _descriptor.Descriptor(
  name='ContextRequest',
  full_name='ContextRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='message', full_name='ContextRequest.message', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=1270,
  serialized_end=1303,
)


_CONTEXTRESPONSE = _descriptor.Descriptor(
  name='ContextResponse',
  full_name='ContextResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='code', full_name='ContextResponse.code', index=0,
      number=1, type=5, cpp_type=1, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='context', full_name='ContextResponse.context', index=1,
      number=2, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='message', full_name='ContextResponse.message', index=2,
      number=3, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=1305,
  serialized_end=1385,
)


_NODESIMPLEREQUEST = _descriptor.Descriptor(
  name='NodeSimpleRequest',
  full_name='NodeSimpleRequest',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='code', full_name='NodeSimpleRequest.code', index=0,
      number=1, type=5, cpp_type=1, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=1387,
  serialized_end=1420,
)


_NODESIMPLERESPONSE = _descriptor.Descriptor(
  name='NodeSimpleResponse',
  full_name='NodeSimpleResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='code', full_name='NodeSimpleResponse.code', index=0,
      number=1, type=5, cpp_type=1, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='message', full_name='NodeSimpleResponse.message', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=1422,
  serialized_end=1473,
)


_FINISHWORKERRESPONSE = _descriptor.Descriptor(
  name='FinishWorkerResponse',
  full_name='FinishWorkerResponse',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='workers', full_name='FinishWorkerResponse.workers', index=0,
      number=1, type=5, cpp_type=1, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='code', full_name='FinishWorkerResponse.code', index=1,
      number=2, type=5, cpp_type=1, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='message', full_name='FinishWorkerResponse.message', index=2,
      number=3, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      serialized_options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  serialized_options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=1475,
  serialized_end=1545,
)

_NODESTATUSMESSAGE.fields_by_name['status'].enum_type = _NODESTATUS
_NODESPEC_PROPSENTRY.containing_type = _NODESPEC
_NODESPEC.fields_by_name['props'].message_type = _NODESPEC_PROPSENTRY
_MLJOBDEF_TASKSENTRY.fields_by_name['value'].message_type = _NODESPEC
_MLJOBDEF_TASKSENTRY.containing_type = _MLJOBDEF
_MLJOBDEF.fields_by_name['tasks'].message_type = _MLJOBDEF_TASKSENTRY
_MLCLUSTERDEF.fields_by_name['job'].message_type = _MLJOBDEF
_NODESPECLIST.fields_by_name['nodes'].message_type = _NODESPEC
_NODESPECRESPONSE.fields_by_name['node_spec'].message_type = _NODESPEC
_CONTEXTPROTO_ROLEPARALLELISMENTRY.containing_type = _CONTEXTPROTO
_CONTEXTPROTO_PROPSENTRY.containing_type = _CONTEXTPROTO
_CONTEXTPROTO.fields_by_name['roleParallelism'].message_type = _CONTEXTPROTO_ROLEPARALLELISMENTRY
_CONTEXTPROTO.fields_by_name['cluster'].message_type = _MLCLUSTERDEF
_CONTEXTPROTO.fields_by_name['props'].message_type = _CONTEXTPROTO_PROPSENTRY
_CONTEXTPROTO.fields_by_name['columnInfos'].message_type = _COLUMNINFOPB
_CONTEXTRESPONSE.fields_by_name['context'].message_type = _CONTEXTPROTO
DESCRIPTOR.message_types_by_name['NodeStatusMessage'] = _NODESTATUSMESSAGE
DESCRIPTOR.message_types_by_name['NodeSpec'] = _NODESPEC
DESCRIPTOR.message_types_by_name['MLJobDef'] = _MLJOBDEF
DESCRIPTOR.message_types_by_name['MLClusterDef'] = _MLCLUSTERDEF
DESCRIPTOR.message_types_by_name['NodeSpecList'] = _NODESPECLIST
DESCRIPTOR.message_types_by_name['NodeSpecRequest'] = _NODESPECREQUEST
DESCRIPTOR.message_types_by_name['NodeSpecResponse'] = _NODESPECRESPONSE
DESCRIPTOR.message_types_by_name['NodeRestartRequest'] = _NODERESTARTREQUEST
DESCRIPTOR.message_types_by_name['NodeRestartResponse'] = _NODERESTARTRESPONSE
DESCRIPTOR.message_types_by_name['NodeStopRequest'] = _NODESTOPREQUEST
DESCRIPTOR.message_types_by_name['NodeStopResponse'] = _NODESTOPRESPONSE
DESCRIPTOR.message_types_by_name['ColumnInfoPB'] = _COLUMNINFOPB
DESCRIPTOR.message_types_by_name['ContextProto'] = _CONTEXTPROTO
DESCRIPTOR.message_types_by_name['ContextRequest'] = _CONTEXTREQUEST
DESCRIPTOR.message_types_by_name['ContextResponse'] = _CONTEXTRESPONSE
DESCRIPTOR.message_types_by_name['NodeSimpleRequest'] = _NODESIMPLEREQUEST
DESCRIPTOR.message_types_by_name['NodeSimpleResponse'] = _NODESIMPLERESPONSE
DESCRIPTOR.message_types_by_name['FinishWorkerResponse'] = _FINISHWORKERRESPONSE
DESCRIPTOR.enum_types_by_name['NodeStatus'] = _NODESTATUS
_sym_db.RegisterFileDescriptor(DESCRIPTOR)

NodeStatusMessage = _reflection.GeneratedProtocolMessageType('NodeStatusMessage', (_message.Message,), {
  'DESCRIPTOR' : _NODESTATUSMESSAGE,
  '__module__' : 'node_pb2'
  # @@protoc_insertion_point(class_scope:NodeStatusMessage)
  })
_sym_db.RegisterMessage(NodeStatusMessage)

NodeSpec = _reflection.GeneratedProtocolMessageType('NodeSpec', (_message.Message,), {

  'PropsEntry' : _reflection.GeneratedProtocolMessageType('PropsEntry', (_message.Message,), {
    'DESCRIPTOR' : _NODESPEC_PROPSENTRY,
    '__module__' : 'node_pb2'
    # @@protoc_insertion_point(class_scope:NodeSpec.PropsEntry)
    })
  ,
  'DESCRIPTOR' : _NODESPEC,
  '__module__' : 'node_pb2'
  # @@protoc_insertion_point(class_scope:NodeSpec)
  })
_sym_db.RegisterMessage(NodeSpec)
_sym_db.RegisterMessage(NodeSpec.PropsEntry)

MLJobDef = _reflection.GeneratedProtocolMessageType('MLJobDef', (_message.Message,), {

  'TasksEntry' : _reflection.GeneratedProtocolMessageType('TasksEntry', (_message.Message,), {
    'DESCRIPTOR' : _MLJOBDEF_TASKSENTRY,
    '__module__' : 'node_pb2'
    # @@protoc_insertion_point(class_scope:MLJobDef.TasksEntry)
    })
  ,
  'DESCRIPTOR' : _MLJOBDEF,
  '__module__' : 'node_pb2'
  # @@protoc_insertion_point(class_scope:MLJobDef)
  })
_sym_db.RegisterMessage(MLJobDef)
_sym_db.RegisterMessage(MLJobDef.TasksEntry)

MLClusterDef = _reflection.GeneratedProtocolMessageType('MLClusterDef', (_message.Message,), {
  'DESCRIPTOR' : _MLCLUSTERDEF,
  '__module__' : 'node_pb2'
  # @@protoc_insertion_point(class_scope:MLClusterDef)
  })
_sym_db.RegisterMessage(MLClusterDef)

NodeSpecList = _reflection.GeneratedProtocolMessageType('NodeSpecList', (_message.Message,), {
  'DESCRIPTOR' : _NODESPECLIST,
  '__module__' : 'node_pb2'
  # @@protoc_insertion_point(class_scope:NodeSpecList)
  })
_sym_db.RegisterMessage(NodeSpecList)

NodeSpecRequest = _reflection.GeneratedProtocolMessageType('NodeSpecRequest', (_message.Message,), {
  'DESCRIPTOR' : _NODESPECREQUEST,
  '__module__' : 'node_pb2'
  # @@protoc_insertion_point(class_scope:NodeSpecRequest)
  })
_sym_db.RegisterMessage(NodeSpecRequest)

NodeSpecResponse = _reflection.GeneratedProtocolMessageType('NodeSpecResponse', (_message.Message,), {
  'DESCRIPTOR' : _NODESPECRESPONSE,
  '__module__' : 'node_pb2'
  # @@protoc_insertion_point(class_scope:NodeSpecResponse)
  })
_sym_db.RegisterMessage(NodeSpecResponse)

NodeRestartRequest = _reflection.GeneratedProtocolMessageType('NodeRestartRequest', (_message.Message,), {
  'DESCRIPTOR' : _NODERESTARTREQUEST,
  '__module__' : 'node_pb2'
  # @@protoc_insertion_point(class_scope:NodeRestartRequest)
  })
_sym_db.RegisterMessage(NodeRestartRequest)

NodeRestartResponse = _reflection.GeneratedProtocolMessageType('NodeRestartResponse', (_message.Message,), {
  'DESCRIPTOR' : _NODERESTARTRESPONSE,
  '__module__' : 'node_pb2'
  # @@protoc_insertion_point(class_scope:NodeRestartResponse)
  })
_sym_db.RegisterMessage(NodeRestartResponse)

NodeStopRequest = _reflection.GeneratedProtocolMessageType('NodeStopRequest', (_message.Message,), {
  'DESCRIPTOR' : _NODESTOPREQUEST,
  '__module__' : 'node_pb2'
  # @@protoc_insertion_point(class_scope:NodeStopRequest)
  })
_sym_db.RegisterMessage(NodeStopRequest)

NodeStopResponse = _reflection.GeneratedProtocolMessageType('NodeStopResponse', (_message.Message,), {
  'DESCRIPTOR' : _NODESTOPRESPONSE,
  '__module__' : 'node_pb2'
  # @@protoc_insertion_point(class_scope:NodeStopResponse)
  })
_sym_db.RegisterMessage(NodeStopResponse)

ColumnInfoPB = _reflection.GeneratedProtocolMessageType('ColumnInfoPB', (_message.Message,), {
  'DESCRIPTOR' : _COLUMNINFOPB,
  '__module__' : 'node_pb2'
  # @@protoc_insertion_point(class_scope:ColumnInfoPB)
  })
_sym_db.RegisterMessage(ColumnInfoPB)

ContextProto = _reflection.GeneratedProtocolMessageType('ContextProto', (_message.Message,), {

  'RoleParallelismEntry' : _reflection.GeneratedProtocolMessageType('RoleParallelismEntry', (_message.Message,), {
    'DESCRIPTOR' : _CONTEXTPROTO_ROLEPARALLELISMENTRY,
    '__module__' : 'node_pb2'
    # @@protoc_insertion_point(class_scope:ContextProto.RoleParallelismEntry)
    })
  ,

  'PropsEntry' : _reflection.GeneratedProtocolMessageType('PropsEntry', (_message.Message,), {
    'DESCRIPTOR' : _CONTEXTPROTO_PROPSENTRY,
    '__module__' : 'node_pb2'
    # @@protoc_insertion_point(class_scope:ContextProto.PropsEntry)
    })
  ,
  'DESCRIPTOR' : _CONTEXTPROTO,
  '__module__' : 'node_pb2'
  # @@protoc_insertion_point(class_scope:ContextProto)
  })
_sym_db.RegisterMessage(ContextProto)
_sym_db.RegisterMessage(ContextProto.RoleParallelismEntry)
_sym_db.RegisterMessage(ContextProto.PropsEntry)

ContextRequest = _reflection.GeneratedProtocolMessageType('ContextRequest', (_message.Message,), {
  'DESCRIPTOR' : _CONTEXTREQUEST,
  '__module__' : 'node_pb2'
  # @@protoc_insertion_point(class_scope:ContextRequest)
  })
_sym_db.RegisterMessage(ContextRequest)

ContextResponse = _reflection.GeneratedProtocolMessageType('ContextResponse', (_message.Message,), {
  'DESCRIPTOR' : _CONTEXTRESPONSE,
  '__module__' : 'node_pb2'
  # @@protoc_insertion_point(class_scope:ContextResponse)
  })
_sym_db.RegisterMessage(ContextResponse)

NodeSimpleRequest = _reflection.GeneratedProtocolMessageType('NodeSimpleRequest', (_message.Message,), {
  'DESCRIPTOR' : _NODESIMPLEREQUEST,
  '__module__' : 'node_pb2'
  # @@protoc_insertion_point(class_scope:NodeSimpleRequest)
  })
_sym_db.RegisterMessage(NodeSimpleRequest)

NodeSimpleResponse = _reflection.GeneratedProtocolMessageType('NodeSimpleResponse', (_message.Message,), {
  'DESCRIPTOR' : _NODESIMPLERESPONSE,
  '__module__' : 'node_pb2'
  # @@protoc_insertion_point(class_scope:NodeSimpleResponse)
  })
_sym_db.RegisterMessage(NodeSimpleResponse)

FinishWorkerResponse = _reflection.GeneratedProtocolMessageType('FinishWorkerResponse', (_message.Message,), {
  'DESCRIPTOR' : _FINISHWORKERRESPONSE,
  '__module__' : 'node_pb2'
  # @@protoc_insertion_point(class_scope:FinishWorkerResponse)
  })
_sym_db.RegisterMessage(FinishWorkerResponse)


DESCRIPTOR._options = None
_NODESPEC_PROPSENTRY._options = None
_MLJOBDEF_TASKSENTRY._options = None
_CONTEXTPROTO_ROLEPARALLELISMENTRY._options = None
_CONTEXTPROTO_PROPSENTRY._options = None
# @@protoc_insertion_point(module_scope)
